package com.vtb.base;

import java.util.HashMap;
import java.util.concurrent.BlockingQueue;

import com.renren.api.client.RenrenApiClient;
import com.tencent.weibo.beans.OAuth;
import com.vtb.entity.Config;
import com.vtb.entity.QqOauth;
import com.vtb.entity.RrOauth;
import com.vtb.entity.SsOauth;



public class VtbBaseReadThread implements Runnable {
    /**
     * 数据发送队列
     */
    protected BlockingQueue<Object> send_queue;                                      
    
    
    /**
     * 腾讯微博遍历队列
     */
    protected BlockingQueue<QqOauth> traver_qqQueue;                      
    /**
     * 新浪微博遍历队列
     */
    protected BlockingQueue<SsOauth> traver_ssQueue;                      
    /**
     * 人人状态遍历队列
     */
    protected BlockingQueue<RrOauth> traver_rrQueue;                      
    
    
    /**
     * 读取的状态发布时间
     */
    protected String statusTime;                                          
    /**
     * 状态上次被放入发送队列时间
     */
    protected String lastTime;                                            
    
    protected RrOauth rrOauth = null;
    protected QqOauth qqOauth = null;
    protected SsOauth ssOauth = null;
    
    
    /**
     * 腾讯微博数据副本
     */
    protected HashMap<String, QqOauth> clone_mapq;                        
    /**
     * 新浪微博数据副本
     */
    protected HashMap<String, SsOauth> clone_maps;                        
    /**
     * 人人数据副本
     */
    protected HashMap<String, RrOauth> clone_mapr;  
    
    
    
    /**
     * 状态内容
     */
    protected String message = null;                                      
    /**
     * 图片地址
     */
    protected String image_url = null;                                    
    /**
     * 消息来源
     */
    protected String source;                                              
    
    public void run() {
        

    }
    
    /**
     * 人人API Client
     */
    protected RenrenApiClient client = RenrenApiClient.getInstance();
    /**
     * 初始化腾讯微博API Oauth
     */
    protected OAuth oauth = new OAuth(Config.QQ_APP_KEY,Config.QQ_APP_SECRET,"");
    
    /**
     * 判断消息来源
     *
     * @param notin 不允许数组
     * @return  包含返回true 
     * @author Chen Tao
     * @date 2012-7-1 下午07:25:21
     */
    protected boolean judgeSource(String[] notin){
        for (int i = 0; i < notin.length; i++) {
            if (source.equals(Config.QQ_FROM[i])) {
                return true;
            }
        }
        return false;
    }

   
}
